Otter之MainStemStatus

    |     mysql mysql   |    

两种状态

 public enum Status {
        /** 已追上 */
        OVERTAKE,
        /** 追赶中 */
        TAKEING;

OVERTAKE是在OtterDownStreamHandler更新的，在CanalEmbedSelector中通过destination产生特定的 CanalInstance的时候，

会把OtterDownStreamHandler添加到handler队列的头

CanalEventSink eventSink = instance.getEventSink();
if (eventSink instanceof AbstractCanalEventSink) {
    handler = new OtterDownStreamHandler();
    handler.setPipelineId(pipelineId);
    handler.setDetectingIntervalInSeconds(canal.getCanalParameter().getDetectingIntervalInSeconds());
    OtterContextLocator.autowire(handler); // 注入一下spring资源
    ((AbstractCanalEventSink) eventSink).addHandler(handler, 0); // 添加到开头
    handler.start();
 }